home *** CD-ROM | disk | FTP | other *** search
/ SGI Developer Toolbox 6.1 / SGI Developer Toolbox 6.1 - Disc 4.iso / public / fax / src / util / xferstats.sh < prev   
Linux/UNIX/POSIX Shell Script  |  1994-08-01  |  10KB  |  409 lines
  1. #! /bin/sh
  2. #    $Header: /usr/people/sam/fax/util/RCS/xferstats.sh,v 1.8 1994/04/18 21:35:05 sam Rel $
  3. #
  4. # FlexFAX Facsimile Software
  5. #
  6. # Copyright (c) 1990, 1991, 1992, 1993, 1994 Sam Leffler
  7. # Copyright (c) 1991, 1992, 1993, 1994 Silicon Graphics, Inc.
  8. # 
  9. # Permission to use, copy, modify, distribute, and sell this software and 
  10. # its documentation for any purpose is hereby granted without fee, provided
  11. # that (i) the above copyright notices and this permission notice appear in
  12. # all copies of the software and related documentation, and (ii) the names of
  13. # Sam Leffler and Silicon Graphics may not be used in any advertising or
  14. # publicity relating to the software without the specific, prior written
  15. # permission of Sam Leffler and Silicon Graphics.
  16. # 
  17. # THE SOFTWARE IS PROVIDED "AS-IS" AND WITHOUT WARRANTY OF ANY KIND, 
  18. # EXPRESS, IMPLIED OR OTHERWISE, INCLUDING WITHOUT LIMITATION, ANY 
  19. # WARRANTY OF MERCHANTABILITY OR FITNESS FOR A PARTICULAR PURPOSE.  
  20. # 
  21. # IN NO EVENT SHALL SAM LEFFLER OR SILICON GRAPHICS BE LIABLE FOR
  22. # ANY SPECIAL, INCIDENTAL, INDIRECT OR CONSEQUENTIAL DAMAGES OF ANY KIND,
  23. # OR ANY DAMAGES WHATSOEVER RESULTING FROM LOSS OF USE, DATA OR PROFITS,
  24. # WHETHER OR NOT ADVISED OF THE POSSIBILITY OF DAMAGE, AND ON ANY THEORY OF 
  25. # LIABILITY, ARISING OUT OF OR IN CONNECTION WITH THE USE OR PERFORMANCE 
  26. # OF THIS SOFTWARE.
  27. #
  28.  
  29. #
  30. # Print Statistics about Transmitted Facsimile.
  31. #
  32. SPOOL=/usr/spool/fax
  33. AWK=nawk
  34.  
  35. PATH=/bin:/usr/bin:/etc
  36. test -d /usr/ucb  && PATH=$PATH:/usr/ucb        # Sun and others
  37. test -d /usr/bsd  && PATH=$PATH:/usr/bsd        # Silicon Graphics
  38. test -d /usr/5bin && PATH=/usr/5bin:$PATH:/usr/etc    # Sun and others
  39. test -d /usr/sbin && PATH=/usr/sbin:$PATH        # 4.4BSD-derived
  40.  
  41. # look for an an awk: nawk, gawk, awk
  42. ($AWK '{}' </dev/null >/dev/null) 2>/dev/null ||
  43.     { AWK=gawk; ($AWK '{}' </dev/null >/dev/null) 2>/dev/null || AWK=awk; }
  44.  
  45. FILES=
  46. SORTKEY=-sender
  47. MAPNAMES=yes
  48.  
  49. while [ x"$1" != x"" ] ; do
  50.     case $1 in
  51.     -send*|-csi|-dest*|-speed|-rate|-format)
  52.         SORTKEY=$1;;
  53.     -nomap) MAPNAMES=no;;
  54.     -*)        echo "Usage: $0 [-sortkey] [-nomap] [files]"; exit 1;;
  55.     *)        FILES="$FILES $1";;
  56.     esac
  57.     shift
  58. done
  59. if [ -z "$FILES" ]; then
  60.     FILES=$SPOOL/etc/xferlog
  61. fi
  62.  
  63. #
  64. # Construct awk rules to collect information according
  65. # to the desired sort key.  There are two rules for
  66. # each; to deal with the two different formats that
  67. # have existed over time.
  68. #
  69. case $SORTKEY in
  70. -send*)
  71.     AWKRULES='$2 == "SEND" && NF == 9  { acct($3, $4, $7, $8, $5, $6, $9); }
  72.                $2 == "SEND" && NF == 11 { acct($4, $5, $9, $10, $7, $8, $11); }'
  73.     ;;
  74. -csi)
  75.     AWKRULES='$2 == "SEND" && NF == 9  { acct($4, $4, $7, $8, $5, $6, $9); }
  76.               $2 == "SEND" && NF == 11 { acct($6, $5, $9, $10, $7, $8, $11); }'
  77.     MAPNAMES=no
  78.     ;;
  79. -dest*)
  80.     AWKRULES='$2 == "SEND" && NF == 9  { acct($4, $4, $7, $8, $5, $6, $9); }
  81.               $2 == "SEND" && NF == 11 { acct($5, $5, $9, $10, $7, $8, $11); }'
  82.     MAPNAMES=no
  83.     ;;
  84. -speed|-rate)
  85.     AWKRULES='$2 == "SEND" && NF == 9  { acct($5, $4, $7, $8, $5, $6, $9); }
  86.               $2 == "SEND" && NF == 11 { acct($7, $5, $9, $10, $7, $8, $11); }'
  87.     MAPNAMES=no
  88.     ;;
  89. -format)
  90.     AWKRULES='$2 == "SEND" && NF == 9  { acct($6, $4, $7, $8, $5, $6, $9); }
  91.               $2 == "SEND" && NF == 11 { acct($8, $5, $9, $10, $7, $8, $11); }'
  92.     MAPNAMES=no
  93.     ;;
  94. esac
  95.  
  96. #
  97. # Generate an awk program to process the statistics file.
  98. #
  99. tmpAwk=/tmp/xfer$$
  100. trap "rm -f $tmpAwk; exit 1" 0 1 2 15
  101.  
  102. (cat<<'EOF'
  103. #
  104. # Convert hh:mm:ss to seconds.
  105. #
  106. func cvtTime(s)
  107. {
  108.     t = i = 0;
  109.     for (n = split(s, a, ":"); i++ < n; )
  110.     t = t*60 + a[i];
  111.     return t;
  112. }
  113.  
  114. func setupDigits()
  115. {
  116.   digits[0] = "0"; digits[1] = "1"; digits[2] = "2";
  117.   digits[3] = "3"; digits[4] = "4"; digits[5] = "5";
  118.   digits[6] = "6"; digits[7] = "7"; digits[8] = "8";
  119.   digits[9] = "9";
  120. }
  121.  
  122. #
  123. # Format seconds as hh:mm:ss.
  124. #
  125. func fmtTime(t)
  126. {
  127.     v = int(t/3600);
  128.     result = "";
  129.     if (v > 0) {
  130.     if (v >= 10)
  131.         result = digits[int(v/10)];
  132.     result = result digits[int(v%10)] ":";
  133.     t -= v*3600;
  134.     }
  135.     v = int(t/60);
  136.     if (v >= 10 || result != "")
  137.     result = result digits[int(v/10)];
  138.     result = result digits[int(v%10)];
  139.     t -= v*60;
  140.     return (result ":" digits[int(t/10)] digits[int(t%10)]);
  141. }
  142.  
  143. #
  144. # Setup a map for histogram calculations.
  145. #
  146. func setupMap(s, map)
  147. {
  148.     n = split(s, a, ":");
  149.     for (i = 1; i <= n; i++)
  150.     map[a[i]] = i;
  151. }
  152.  
  153. #
  154. # Add pages to a histogram.
  155. #
  156. func addToMap(key, ix, pages, map)
  157. {
  158.     if (key == "") {
  159.     for (i in map)
  160.         key = key ":";
  161.     }
  162.     n = split(key, a, ":");
  163.     a[map[ix]] += pages;
  164.     t = a[1];
  165.     for (i = 2; i <= n; i++)
  166.       t = t ":" a[i];
  167.     return t;
  168. }
  169.  
  170. #
  171. # Merge two histogram maps.
  172. #
  173. func mergeMap(map2, map1)
  174. {
  175.     if (map2 == "")
  176.     return map1;
  177.     else if (map1 == "")
  178.     return map2;
  179.     # map1 & map2 are populated
  180.     n1 = split(map1, a1, ":");
  181.     n2 = split(map2, a2, ":");
  182.     for (i = 1; i <= n1; i++)
  183.     a2[i] += a1[i];
  184.     t = a2[1];
  185.     for (i = 2; i <= n; i++)
  186.       t = t ":" a2[i];
  187.     return t;
  188. }
  189.  
  190. #
  191. # Return the name of the item with the
  192. # largest number of accumulated pages.
  193. #
  194. func bestInMap(totals, map)
  195. {
  196.    n = split(totals, a, ":");
  197.    imax = 1; max = -1;
  198.    for (j = 1; j <= n; j++)
  199.        if (a[j] > max) {
  200.        max = a[j];
  201.        imax = j;
  202.        }
  203.    split(map, a, ":");
  204.    return a[imax];
  205. }
  206.  
  207. #
  208. # Sort array a[l..r]
  209. #
  210. function qsort(a, l, r) {
  211.     i = l;
  212.     k = r+1;
  213.     item = a[l];
  214.     for (;;) {
  215.     while (i < r) {
  216.             i++;
  217.         if (a[i] >= item)
  218.         break;
  219.         }
  220.     while (k > l) {
  221.             k--;
  222.         if (a[k] <= item)
  223.         break;
  224.         }
  225.         if (i >= k)
  226.         break;
  227.     t = a[i]; a[i] = a[k]; a[k] = t;
  228.     }
  229.     t = a[l]; a[l] = a[k]; a[k] = t;
  230.     if (k != 0 && l < k-1)
  231.     qsort(a, l, k-1);
  232.     if (k+1 < r)
  233.     qsort(a, k+1, r);
  234. }
  235.  
  236. func cleanup(s)
  237. {
  238.     gsub("\"", "", s);
  239.     gsub("^ +", "", s);
  240.     gsub(" +$", "", s);
  241.     return s;
  242. }
  243.  
  244. func setupToLower()
  245. {
  246.     upperRE = "[ABCDEFGHIJKLMNOPQRSTUVWXYZ]";
  247.     upper["A"] = "a"; upper["B"] = "b"; upper["C"] = "c";
  248.     upper["D"] = "d"; upper["E"] = "e"; upper["F"] = "f";
  249.     upper["G"] = "g"; upper["H"] = "h"; upper["I"] = "i";
  250.     upper["J"] = "j"; upper["K"] = "k"; upper["L"] = "l";
  251.     upper["M"] = "m"; upper["N"] = "n"; upper["O"] = "o";
  252.     upper["P"] = "p"; upper["Q"] = "q"; upper["R"] = "r";
  253.     upper["S"] = "s"; upper["T"] = "t"; upper["U"] = "u";
  254.     upper["V"] = "v"; upper["W"] = "w"; upper["X"] = "x";
  255.     upper["Y"] = "y"; upper["Z"] = "z";
  256. }
  257.  
  258. func toLower(s)
  259. {
  260.     if (match(s, upperRE) != 0) {
  261.     do {
  262.         c = substr(s, RSTART, 1);
  263.         gsub(c, upper[c], s);
  264.     } while (match(s, upperRE));
  265.     }
  266.     return s;
  267. }
  268.  
  269. #
  270. # Accumulate a statistics record.
  271. #
  272. func acct(key, dest, pages, time, br, df, status)
  273. {
  274.     status = cleanup(status);
  275.     if (length(status) > 11) {
  276.     msg = toLower(substr(status, 1, 11));
  277.     if (callFailed[msg])
  278.         return;
  279.     }
  280.     key = cleanup(key);
  281. EOF
  282. test "$MAPNAMES" = "yes" && cat<<'EOF'
  283.     #
  284.     # Try to merge unqualified names w/ fully qualified names
  285.     # by stripping the host part of the domain address and
  286.     # mapping unqualified names to a stripped qualified name.
  287.     #
  288.     n = split(key, parts, "@");
  289.     if (n == 2) {            # user@addr
  290.     user = parts[1];
  291.     if (user != "root" && user != "guest") {
  292.         addr = parts[2];
  293.         #
  294.         # Strip hostname from multi-part domain name.
  295.         #
  296.         n = split(addr, domains, ".");
  297.         if (n > 1) {        # e.g. flake.asd.sgi.com
  298.         l = length(domains[1])+1;
  299.         addr = substr(addr, l+1, length(addr)-l);
  300.         key = user "@" addr;
  301.         }
  302.         if (addrs[user] == "") {    # record mapped name
  303.         addrs[user] = addr;
  304.         } else if (addrs[user] != addr) {
  305.         if (!warned[user "@" addr]) {
  306.             warned[user "@" addr] = 1;
  307.             printf "Warning, address clash, \"%s\" and \"%s\".\n", \
  308.                user "@" addrs[user], user "@" addr
  309.         }
  310.         }
  311.     }
  312.     } else if (n != 1) {
  313.     printf "Warning, weird user address/name \"%s\".\n", key
  314.     }
  315. EOF
  316. cat<<'EOF'
  317.     dest = cleanup(dest);
  318.     sendpages[key] += pages;
  319.     time = cleanup(time);
  320.     if (pages == 0 && time > 60)
  321.     time = 0;
  322.     sendtime[key] += cvtTime(time);
  323.     if (status != "")
  324.     senderrs[key]++;
  325.     br = cleanup(br);
  326.     sendrate[key] = addToMap(sendrate[key], br, pages, rateMap);
  327.     df = cleanup(df);
  328.     senddata[key] = addToMap(senddata[key], df, pages, dataMap);
  329. }
  330.  
  331. #
  332. # Print a rule between the stats and the totals line.
  333. #
  334. func printRule(n, s)
  335. {
  336.     r = "";
  337.     while (n-- >= 0)
  338.     r = r s;
  339.     printf "%s\n", r;
  340. }
  341.  
  342. BEGIN        { FS="\t";
  343.           rates = "2400:4800:7200:9600:12000:14400";
  344.           setupMap(rates, rateMap);
  345.           datas = "1-D MR:2-D MR:2-D Uncompressed Mode:2-D MMR";
  346.           setupMap(datas, dataMap);
  347.           callFailed["busy signal"] = 1;
  348.           callFailed["unknown pro"] = 1;
  349.           callFailed["no carrier "] = 1;
  350.           callFailed["no local di"] = 1;
  351.           callFailed["no answer f"] = 1;
  352.           setupToLower();
  353.         }
  354. END        { OFS="\t"; setupDigits();
  355.           maxlen = 15;
  356.           # merge unqualified and qualified names
  357.           for (key in sendpages) {
  358.               if (addrs[key] != "") {
  359.               fullkey = key "@" addrs[key];
  360.               sendpages[fullkey] += sendpages[key];
  361.               sendtime[fullkey] += sendtime[key];
  362.               senderrs[fullkey] += senderrs[key];
  363.               sendrate[fullkey] = \
  364.                   mergeMap(sendrate[fullkey], sendrate[key]);
  365.               senddata[fullkey] = \
  366.                   mergeMap(senddata[fullkey], senddata[key]);
  367.               }
  368.           }
  369.           nsorted = 0;
  370.           for (key in sendpages) {
  371.               if (addrs[key] != "")    # unqualified name
  372.               continue;
  373.               l = length(key);
  374.               if (l > maxlen)
  375.             maxlen = l;
  376.               sorted[nsorted++] = key;
  377.           }
  378.           qsort(sorted, 0, nsorted-1);
  379.           fmt = "%-" maxlen "." maxlen "s";    # e.g. %-24.24s
  380.           printf fmt " %5s %8s %6s %4s %7s %7s\n",
  381.               "Destination", "Pages", "Time", "Pg/min",
  382.               "Errs", "TypRate", "TypData";
  383.           tpages = 0;
  384.           ttime = 0;
  385.           terrs = 0;
  386.           for (k = 0; k < nsorted; k++) {
  387.               i = sorted[k];
  388.               t = sendtime[i]/60; if (t == 0) t = 1;
  389.               n = sendpages[i]; if (n == 0) n = 1;
  390.               brate = best
  391.               printf fmt " %5d %8s %6.1f %4d %7d %7.7s\n",
  392.               i, sendpages[i], fmtTime(sendtime[i]),
  393.               sendpages[i] / t, senderrs[i],
  394.               bestInMap(sendrate[i], rates),
  395.               bestInMap(senddata[i], datas);
  396.             tpages += sendpages[i];
  397.             ttime += sendtime[i];
  398.             terrs += senderrs[i];
  399.           }
  400.           printRule(maxlen+1+5+1+8+6+1+4+1+7+1+7, "-");
  401.           t = ttime/60; if (t == 0) t = 1;
  402.           printf fmt " %5d %8s %6.1f %4d\n",
  403.               "Total", tpages, fmtTime(ttime), tpages/t, terrs;
  404.         }
  405. EOF
  406. echo "$AWKRULES"
  407. )>$tmpAwk
  408. $AWK -f $tmpAwk $FILES
  409.